package com.akkainaction.dispatcher.hello.actor;

import akka.actor.UntypedActor;

import java.util.concurrent.TimeUnit;

public class ActorPinnedDemo extends UntypedActor {

    @Override
    public void onReceive(Object msg) throws Exception {
        System.out.println(getSelf() + "--->" + msg + " " + Thread.currentThread().getName());
        TimeUnit.SECONDS.sleep(5);
    }
}
